package edu.ctbu.ljy.bot.Service.impl;

import edu.ctbu.ljy.bot.constain.ConversationConfig;
import edu.ctbu.ljy.bot.constain.RoleContent;
import edu.ctbu.ljy.bot.util.MyWebSocketListener;
import okhttp3.*;
import org.springframework.stereotype.Service;

import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.*;

@Service
public class TalkService {
    public static ConversationConfig res = new ConversationConfig();;
    public int times = 0;
    public String talk(String str) throws Exception{
        res.NewQuestion = str;
        String authUrl = getAuthUrl(res.hostUrl, res.apiKey, res.apiSecret);
        OkHttpClient client = new OkHttpClient.Builder().build();
        String url = authUrl.toString().replace("http://", "ws://").replace("https://", "wss://");
        Request request = new Request.Builder().url(url).build();
        res.totalAnswer="";
        setRoleContentBackground();
        WebSocket webSocket = client.newWebSocket(request, new MyWebSocketListener(res));

        while(!res.wsCloseFlag){
            Thread.sleep(20);
        }

        res.wsCloseFlag = false;

        return res.totalAnswer;
    }

     public static void setRoleContentBackground(){
        res.roleContentBackground.add(new RoleContent("system","你是一位论文查新工作者"));
        res.roleContentBackground.add(new RoleContent("system","当用户要求你总结科学技术要点，你分析用户的给出的材料，总结出查新点，分点列出并且最多给出三点"));
        res.roleContentBackground.add(new RoleContent("system","这是用户发给你的材料：目前传统疫情防控中，排查密切接触者主要以人工流调入户排查为主，该方式耗时较长、效率较低、易出疏漏。确诊患者的完整接触记录非常复杂，难以做到精细的密切接触者排查。据国家卫健委调查显示，一个确诊患者需要数名流调人员平均花费3到5天的时间才能回溯其14天内的接触史。在疫情爆发期间，多数城市和国家没有能力抽调足够人力对每一个确诊患者的接触史进行排查，无法发现并隔离全部密切接触者，只能进行封城和地毯式的全民核酸检测。在国家经济发展的关键时期，因疫情停工停产导致的经济衰退越来越不可接受。如何快速精准查找新冠患者的所有密切接触者，尽早阻断病毒传播链，减少疫情对国家经济的影响，保护国民生命安全是当今疫情防控要解决的首要问题。\n" +
                "本作品主要采用RFID射频技术和人工智能知识图谱技术来实现密切接触者的快速查找。系统通过RFID阅读器采集区域内RFID标签数据（用户ID与RSSI值)，基于RSSI信号衰减模型与加权定位算法求解各标签相对距离数据，再由知识图谱技术基于采集数据构建区域人员的接触网络，根据接触网络实现患者密切接触者的快速查找。目前国内排查密切接触者以人工流调排查方式为主，该方式存在耗时长、效率较低、易出疏漏等问题，难以保证排查的精确度。国外密切触者查询多以手机蓝牙技术为主，通过患者APP蓝牙功能追踪密切接触者，但实际使用时却存在难以保证每个人都下载APP、无法保证APP一直后台运行、无法记录无手机人员（儿童与老人）接触数据等诸多问题。本作品的主要运用场景是机场、车站、学校、医院等企事业单位或大型活动、会议场所。在此类场景下RFID标签贴纸可贴在车票、工作证上。相较于基于APP蓝牙技术的密切接触者排查方式，本作品在此类场景下更能保证采集数据的完整性，不会出现因没带手机、没有网络、APP没后台运行而导致接触数据丢失问题。相较于传统人工流调方式，本作品能大大缩短密切接触者排查时间，具有显著优势。"));

    }

    // 鉴权方法
    public static String getAuthUrl(String hostUrl, String apiKey, String apiSecret) throws Exception {
        URL url = new URL(hostUrl);
        // 时间
        SimpleDateFormat format = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss z", Locale.US);
        format.setTimeZone(TimeZone.getTimeZone("GMT"));
        String date = format.format(new Date());
        // 拼接
        String preStr = "host: " + url.getHost() + "\n" +
                "date: " + date + "\n" +
                "GET " + url.getPath() + " HTTP/1.1";
        // System.err.println(preStr);
        // SHA256加密
        Mac mac = Mac.getInstance("hmacsha256");
        SecretKeySpec spec = new SecretKeySpec(apiSecret.getBytes(StandardCharsets.UTF_8), "hmacsha256");
        mac.init(spec);

        byte[] hexDigits = mac.doFinal(preStr.getBytes(StandardCharsets.UTF_8));
        // Base64加密
        String sha = Base64.getEncoder().encodeToString(hexDigits);
        // System.err.println(sha);
        // 拼接
        String authorization = String.format("api_key=\"%s\", algorithm=\"%s\", headers=\"%s\", signature=\"%s\"", apiKey, "hmac-sha256", "host date request-line", sha);
        // 拼接地址
        HttpUrl httpUrl = Objects.requireNonNull(HttpUrl.parse("https://" + url.getHost() + url.getPath())).newBuilder().//
                addQueryParameter("authorization", Base64.getEncoder().encodeToString(authorization.getBytes(StandardCharsets.UTF_8))).//
                addQueryParameter("date", date).//
                addQueryParameter("host", url.getHost()).//
                build();

        // System.err.println(httpUrl.toString());
        return httpUrl.toString();
    }


}
